package com.lkd.emq;

import org.eclipse.paho.client.mqttv3.MqttMessage;

public interface MqttService {

    /**
     * 消息处理接口
     * @param topic
     * @param message
     */
    void processMessage(String topic, MqttMessage message);
}
